<?php
$cur_dir = dirname(__FILE__); 
chdir($cur_dir); 
require './RunDbPdo.php';
require './RedisQ.php';
$model = new RunDbPdo();
$model->configFile = "./dbconfig/user.config.php";
$redis = new RedisQ();
$do = true;
while ($do) {
    $data = $redis->rpop('sql');
    if(empty($data)){
        break;
    }
    $resu = $model->query($data);
    if(!$resu){
        file_put_contents('que_error', $data);
    }
    echo $data."\r\n";
}

